package com.gjy.kafka.sp.entity;

import lombok.Data;

import java.io.Serializable;
import java.time.LocalDateTime;

/**
 * 消息实体类
 * 用于封装发送到Kafka的消息内容
 *
 * @author gjy
 * @version 1.0
 * @since 2025-09-07 10:31:59
 */
@Data
public class MessageEntity implements Serializable {

    private static final long serialVersionUID = -448198112016325124L;

    /**
     * 消息ID
     */
    private String messageId;

    /**
     * 消息内容
     */
    private String content;

    /**
     * 业务类型
     */
    private String businessType;

    /**
     * 业务ID，用于分区策略
     */
    private String businessId;

    /**
     * 创建时间
     */
    private LocalDateTime createTime;

    /**
     * 扩展字段，用于存储额外信息
     */
    private String extra;

}
